package dsmflex.taskengine;

import java.util.Map;

import org.apache.log4j.Logger;

import com.liusy.taskengine.taskmodel.AbstractDBTaskModel;


/**
 * 批量执行sql的具体任务
 * 
 * @author liusy 2012-12-11
 */
public class SqlTaskModel extends AbstractDBTaskModel{

	private static Logger log = Logger.getLogger(SqlTaskModel.class);
	
	
	public SqlTaskModel(Map<String,Object> rowMap)
	{
		super(rowMap);
	}
	
	@Override
	public String getSql() {
		return "select wm_concat(t.consumer_id) customerId  from ex_customer_sub t where t.consumer_name = '"+rowMap.get("name")+"' group by t.consumer_name";
	}

}
